package com.sanshengshui.iot.common.subscribe;

import java.util.List;

// 订阅存储服务接口
public interface GrozaSubscribeStoreService {
    // 保存订阅
    void put(String topicFilter, SubscribeStore subscribeStore);

    // 删除订阅
    void remove(String topicFilter, String clientId);

    // 删除clientId的订阅
    void removeForClient(String clientId);

    // 获取订阅存储集
    List<SubscribeStore> search(String topic);
}
